package com.atguigu.flink.edu.app.dws;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class dws_Trade_Order_Course_Amount {
    public static void main(String[] args) {
        //TODO 1:基本环境设置
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(4);
        //TODO 2:检查点设置
        //TODO 3:从kafka读取支付数据

    }
}
